package com.staryea.kafkatomysql.mapper;

import com.alibaba.fastjson.JSONObject;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

import java.util.List;
import java.util.Map;

/**
 * @author gonghl@staryea.com
 * @since 2022/6/12
 */
@Mapper
public interface KafkaToMysqlMapper {

    int batchAddData(@Param("list") List<Map<String, Object>> list, @Param("table") String table);
}
